package com.kingsoft.dc.khaos.module

import com.kingsoft.dc.khaos.{DataSetChannel, KhaosContext, SchemaChannel}
import com.kingsoft.dc.khaos.metadata.Dependency
import org.apache.spark.rdd.RDD

/**
  * Created by chengguangqing on 2019/6/2.
  */
trait TSource {
  type MapSet = Map[String, String]

  def source(_mid: String,
             kc: KhaosContext,
             config: String,
             dependence: Dependency,
             dataCollector: DataSetChannel,
             declarer: SchemaChannel): Any = {}

  def source(_mid: String,
             dc: KhaosContext,
             config: Any,
             dataCollector: DataSetChannel
            ): Any = {}
}
